package com.kin207.netty.listener.message;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.kin207.netty.context.RequestContext;
import com.kin207.netty.handle.IMessageHandle;
import com.kin207.netty.listener.ListenerConfig;
import com.kin207.netty.listener.MessageHandleListener;
import com.kin207.netty.session.Session;

/**
 * 消息mq转发监听器
 * @author kin207
 *
 */
public class MQRelayMessageHandleListener implements MessageHandleListener {
	final static Logger logger = LoggerFactory.getLogger(MQRelayMessageHandleListener.class);
	
	private String quauaServer;
	private String quauaName;

	public void initialize(ListenerConfig cfg) {
		
	}

	public void created(IMessageHandle t) {
		String msg = RequestContext.curr.get().getMessage();
		System.out.println("mq replay:"+msg);
	}

	public void destroyed(IMessageHandle t) {
		// TODO Auto-generated method stub
		
	}

	

}
